package com.qilin.hscs.hm.mqtt.config;

import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;

/**
 * Created by 10188 on 2018/3/20.
 */
public interface Doubleflush {

    void send(MqttClient client, String messageStr, String topicStr) throws MqttException;

    void receive(MqttClient client, String topicStr, MqttCallback callback) throws MqttException;
}
